logging.level.root=WARN
logging.level.org.springframework=INFO
logging.level.org.apache=INFO
logging.level.pw.avvero=TRACE
logging.level.pw.avvero.emk.KafkaSupport=DEBUG
#logging.level.org.springframework.kafka=TRACE

spring.kafka.bootstrap-servers=localhost:9092

spring.kafka.consumer.enable-auto-commit=false
spring.kafka.listener.ack-mode=record
spring.kafka.listener.poll-timeout=1000
spring.kafka.consumer.auto-offset-reset=latest
spring.kafka.producer.acks=1
spring.kafka.producer.retries=5
spring.kafka.properties.security.protocol=PLAINTEXT

spring.kafka.listener.missing-topics-fatal=false

# Reduce latency for consumer
spring.kafka.consumer.max-poll-records=10
spring.kafka.consumer.fetch-max-wait=0
spring.kafka.consumer.heartbeat-interval=1000
spring.kafka.consumer.properties.session.timeout.ms=10000
spring.kafka.consumer.properties.max.poll.interval.ms=10000
spring.kafka.listener.concurrency=1

# Reduce latency for producer
spring.kafka.producer.batch-size=0
spring.kafka.producer.buffer-memory=16777216
spring.kafka.producer.properties.max.in.flight.requests.per.connection=1
spring.kafka.producer.properties.request.timeout.ms=15000
spring.kafka.producer.properties.delivery.timeout.ms=60000

emk.event-captor.topics=topic0,topic1,topic2,topic3,topic4,topic5,topic6,topic7,topic8,topic9,topic10,topicBroken,topicBroken-retry,topicBroken-dlt